package com.navinfo.platform.dataanalysis.service;

import com.navinfo.platform.common.dto.DataInfo;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

import java.util.List;
import java.util.Map;

/**
 * @author machi
 * @create 2018/11/26
 **/
public interface IVehicleBaseStatisticsDayService {
    JavaPairRDD<Long, List<DataInfo>> convert(Dataset<Row> locationDataset, Map<String, String> configMap);

    Dataset<Row> handle(JavaPairRDD<Long, List<DataInfo>> javaPairRDD,
                                                       Dataset<Row> idleDataset,Dataset<Row> tileDataset,
                                                       Map<String, String> configMap,
                                                       SparkSession spark);
}
